package org.example.function;

import lombok.RequiredArgsConstructor;
import org.apache.flink.api.common.functions.FilterFunction;
import org.example.data.WaterSensor;

@RequiredArgsConstructor
public class FilterFunctionImpl implements FilterFunction<WaterSensor> {
    private final String id;

    @Override
    public boolean filter(WaterSensor value) throws Exception {
        return this.id.equals(value.getId());
    }
}
